package cc.linker.steplink.crm.configuration;


import org.springframework.context.annotation.Configuration;

/**
 * @Description: 队列延时可以用于倒计时
 * @Author: ch
 * @Date: 2020/4/21 17:15
**/
@Configuration
public class MqTimeConfig {
//    /**
//     * 自定义的交换机类型
//     * @return
//     */
//    @Bean
//    CustomExchange delayedExchange() {
//        Map<String,Object> args = new HashMap<>();
//        args.put("x-delayed-type", "direct");
//        return new CustomExchange("delayedExchange","x-delayed-message",true,false,args);
//    }
//
//    /**
//     * 创建一个队列
//     * @return
//     */
//    @Bean
//    public Queue delayedQueue() {
//        return new Queue("delayedQueue",true);
//    }
//
//    /**
//     * 绑定队列到自定义交换机
//     * @return
//     */
//    @Bean
//    public Binding bindingNotify() {
//        return BindingBuilder.bind(delayedQueue()).to(delayedExchange()).with("delayedQueue").noargs();
//    }


}